package cn.getech.data.development.enums

/**
 * hdfs文件写入方式
 */
object FlinkStreamStartUpMode extends Enumeration {
  type FlinkStreamStartUpMode = Value
  val EARLIEST = Value("EARLIEST")
  val LATEST = Value("LATEST")
  val GROUPOFFSETS = Value("GROUP-OFFSETS")
  val SPECIFICOFFSETS = Value("SPECIFIC-OFFSETS")
}

